package com.hw.one.transpot.fileupload.job;

import com.hw.one.collect.job.Job;
import com.hw.one.transpot.fileupload.util.FileTransportClientUtil;
import com.hw.one.transpot.fileupload.util.ShredUtil;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;

/**
 * @Class ResumeDealJob：从断点处上传job
 * @Author guoshenzhen
 * @Date 2018/3/14  15:59
 */
@Component
public class ResumeDealJob extends Job {
    private Logger log = Logger.getLogger(this.getClass());
    @Override
    public void start(){
        log.debug(this.getClass().getSimpleName() + ".start--->>>transport starting...");
        deal();
        log.debug(this.getClass().getSimpleName() + ".start--->>>transport ended...");
    }

    /**
     *  作用：网络断开之后重新进行上传
     *  配置job 时间需要 和 上传job 错开
     */
    public void deal() {
        // 判断分片上传配置文件是否存在
        if(ShredUtil.existsConfFile()){
            // 如果配置文件存在，进行上传
            new FileTransportClientUtil().connect(FileTransportClientUtil.FILE_IP, FileTransportClientUtil.FILE_PORT, null);
            log.debug("ResumeDealJob.deal 从断点处上传job 已经执行");
        }
    }


}
